package cn.monkey.transport.netty;

import cn.monkey.transport.core.Inbound;
import io.netty.buffer.ByteBuf;
import io.netty.channel.Channel;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import java.net.SocketAddress;
import java.util.concurrent.Flow;

public interface NettyInbound extends Inbound {

    Channel channel();

    default SocketAddress localAddress() {
        return this.channel().localAddress();
    }

    default SocketAddress remoteAddress() {
        return this.channel().remoteAddress();
    }
}
